import logging

from celery_tasks.main import celery_app
from celery_tasks.sms.utils.yuntongxun.sms import CCP

logger = logging.getLogger("django")

# 短信验证码模板
SMS_CODE_TEMP_ID = 1


@celery_app.task(name="send_sms_code")
def send_sms_code(mobile, sms_code, expires):
    """发送短信验证码"""
    try:
        ccp = CCP()
        result = ccp.send_template_sms(mobile, [sms_code, expires],
                                       SMS_CODE_TEMP_ID)
        print(result)
    except Exception as e:
        logger.error("发送短信验证码【异常】[mobile: %s, message: %s]" % (mobile, e))
    else:
        if result == 0:
            logger.info("发送验证码短信【正常】, [mobile: %s]" % mobile)

        else:
            logger.warning("发送验证码短信【失败】[mobile: %s]" % mobile)
